package com.yitiao.simple.tcp;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import lombok.SneakyThrows;


public class NettyServer {
    public static void main(String[] args) {
        // Boss Group（只处理连接请求） 和 Work Group（处理客户端业务） 两个核心
        // 子线程 NioEventLoop  无限循环三步  接受-分发-启动

        // 传参：含有的子线程(NioEventLoop)的个数，默认为 cpu核数 * 2
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup(); //16

        // 创建服务器对象
        startServer(bossGroup, workerGroup);

    }

    @SneakyThrows
    private static void startServer(EventLoopGroup bossGroup, EventLoopGroup workerGroup) {
        ServerBootstrap server = new ServerBootstrap();
        // 设置 server 链式编程
        server.channel(NioServerSocketChannel.class)
                .group(bossGroup, workerGroup)
                .option(ChannelOption.SO_BACKLOG, 128) // 设置线程队列得到连接个数
                .childOption(ChannelOption.SO_KEEPALIVE, true) //设置保持活动连接状态
//                    .handler(null) // 该 handler对应 bossGroup , childHandler 对应 workerGroup
                .childHandler(new ChannelInitializer<SocketChannel>() {//创建一个通道初始化对象(匿名对象)
                    //给pipeline 设置处理器
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {

//                        System.out.println(ch.remoteAddress().getPort());
//                        System.out.println("客户 socket channel hashcode=" + ch.hashCode());
                        //可以使用一个集合管理 SocketChannel， 再推送消息时，
                        // 可以将业务加入到各个channel 对应的 NIOEventLoop 的 taskQueue 或者 scheduleTaskQueue
                        ch.pipeline().addLast(new NettyServerHandler());
                    }
                }); // 给我们的workerGroup 的 EventLoop 对应的管道设置处理器


        //启动服务器(并绑定端口)
        ChannelFuture channelFuture = server.bind(9100).sync();
        System.out.println("server is started,the port is [9100].");

        // 注册监听器
        channelFuture.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                if (channelFuture.isSuccess()) {
                    System.out.println("监听端口 成功");
                } else {
                    System.out.println("监听端口 失败");
                }
            }
        });

        //对关闭通道进行监听
        channelFuture.channel().closeFuture().sync();

        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}
